package com.bml.architect.rocketmq;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
@EnableBinding({Source.class})
@SpringBootApplication
/**
 * spring cloud stream是一块整合了大部分的消息中间件的框架
 * 如果切换中间件只需要在配置文件中更改即可，不需要修改代码，但是整合的中间件中的
 * 消息框架只能公用发送的一些特性，而每个中间件的特性就需要自己去实现了
 * 比如Rocketmq的事务消息就需要自己使用RocketMqTemplate来实现
 */
public class StreamRocketMqApplication {

    public static void main(String[] args) {
        SpringApplication.run(StreamRocketMqApplication.class,args);
    }
}
